package com.algo.pattern.observable.queue;

import com.algo.pattern.observable.model.StockUpdateMessage;

public interface StockUpdateQueueManager {

    void put(StockUpdateMessage message);

    StockUpdateMessage take() throws InterruptedException;
}
